package cn.wanda.topologies.bases

import cn.wanda.topologies.SparkTopoContext
import org.apache.spark.SparkConf
import org.apache.spark.sql.SparkSession
import org.apache.spark.streaming.dstream.InputDStream

trait SparkTopology {

  def config (context:SparkTopoContext,conf:SparkConf)
}
